home *** CD-ROM | disk | FTP | other *** search
/ Internet Info 1994 March / Internet Info CD-ROM (Walnut Creek) (March 1994).iso / networking / ip / ka9q / alpha.arc / AX25USER.C < prev    next >
C/C++ Source or Header  |  1988-07-24  |  3KB  |  156 lines
  1. /* User subroutines for AX.25 */
  2. #include "global.h"
  3. #include "mbuf.h"
  4. #include "timer.h"
  5. #include "iface.h"
  6. #include "ax25.h"
  7. #include "lapb.h"
  8. #include <ctype.h>
  9.  
  10. /* Open an AX.25 connection */
  11. struct ax25_cb *
  12. open_ax25(addr,window,r_upcall,t_upcall,s_upcall,iface,user)
  13. struct ax25 *addr;        /* Addresses */
  14. int16 window;            /* Window size in bytes */
  15. void (*r_upcall)();        /* Receiver upcall handler */
  16. void (*t_upcall)();        /* Transmitter upcall handler */
  17. void (*s_upcall)();        /* State-change upcall handler */
  18. struct interface *iface;    /* Hardware interface structure */
  19. char *user;            /* User linkage area */
  20. {
  21.     struct ax25_cb *axp,*cr_ax25();
  22.     void lapbstate();
  23.  
  24.     if((axp = cr_ax25(&addr->dest)) == NULLAX25)
  25.         return NULLAX25;
  26.     ASSIGN(axp->addr,*addr);
  27.     if(addr->ndigis != 0){
  28.         axp->t1.start *= (addr->ndigis + 1);
  29.         axp->t2.start *= (addr->ndigis + 1);
  30.         axp->t3.start *= (addr->ndigis + 1);
  31.     }
  32.     axp->window = window;
  33.     axp->r_upcall = r_upcall;
  34.     axp->t_upcall = t_upcall;
  35.     axp->s_upcall = s_upcall;
  36.     axp->interface = iface;
  37.     axp->user = user;
  38.  
  39.     switch(axp->state){
  40.     case DISCONNECTED:
  41.         /* Don't send anything if the connection already exists */
  42.         est_link(axp);
  43.         lapbstate(axp,SETUP);
  44.         break;
  45.     case SETUP:
  46.         free_q(&axp->txq);
  47.         break;
  48.     case DISCPENDING:    /* Ignore */
  49.     case FRAMEREJECT:
  50.         break;
  51.     case RECOVERY:
  52.     case CONNECTED:
  53.         free_q(&axp->txq);
  54.         est_link(axp);
  55.         lapbstate(axp,SETUP);
  56.         break;
  57.     }
  58.     return axp;
  59. }
  60.  
  61. /* Send data on an AX.25 connection. Caller must provide PID */
  62. int
  63. send_ax25(axp,bp)
  64. struct ax25_cb *axp;
  65. struct mbuf *bp;
  66. {
  67.     if(axp == NULLAX25 || bp == NULLBUF)
  68.         return -1;
  69.     enqueue(&axp->txq,bp);
  70.     return lapb_output(axp);
  71. }
  72.  
  73. /* Receive incoming data on an AX.25 connection */
  74. struct mbuf *
  75. recv_ax25(axp,cnt)
  76. register struct ax25_cb *axp;
  77. int16 cnt;
  78. {
  79.     struct mbuf *bp;
  80.  
  81.     if(axp->rxq == NULLBUF)
  82.         return NULLBUF;
  83.  
  84.     bp = axp->rxq;
  85.     axp->rxq = NULLBUF;
  86.  
  87.     /* If this has un-busied us, send a RR to reopen the window */
  88.     if(len_mbuf(bp) >= axp->window)
  89.         sendctl(axp,RESPONSE,RR);
  90.     return bp;
  91. }
  92.  
  93. /* Close an AX.25 connection */
  94. disc_ax25(axp)
  95. struct ax25_cb *axp;
  96. {
  97.     void lapbstate();
  98.  
  99.     switch(axp->state){
  100.     case DISCONNECTED:
  101.         break;        /* Ignored */
  102.     case DISCPENDING:
  103.         lapbstate(axp,DISCONNECTED);
  104.         del_ax25(axp);
  105.         break;
  106.     case CONNECTED:
  107.     case RECOVERY:
  108.     case FRAMEREJECT:
  109.         free_q(&axp->txq);
  110.         axp->retries = 0;
  111.         sendctl(axp,COMMAND,DISC|PF);
  112.         stop_timer(&axp->t3);
  113.         start_timer(&axp->t1);
  114.         lapbstate(axp,DISCPENDING);
  115.         break;
  116.     }
  117. }
  118.  
  119. /* Verify that axp points to a valid ax25 control block */
  120. ax25val(axp)
  121. struct ax25_cb *axp;
  122. {
  123.     register struct ax25_cb *axp1;
  124.     register int i;
  125.  
  126.     if(axp == NULLAX25)
  127.         return 0;    /* Null pointer can't be valid */
  128.     for(i=0; i < NHASH; i++)
  129.         for(axp1 = ax25_cb[i];axp1 != NULLAX25; axp1 = axp1->next)
  130.             if(axp1 == axp)
  131.                 return 1;
  132.     return 0;
  133. }
  134.  
  135. /* Force a retransmission */
  136. kick_ax25(axp)
  137. struct ax25_cb *axp;
  138. {
  139.     void recover();
  140.  
  141.     if(!ax25val(axp))
  142.         return -1;
  143.     recover((int *)axp);
  144.     return 0;
  145. }
  146.  
  147. /* Abruptly terminate an AX.25 connection */
  148. reset_ax25(axp)
  149. struct ax25_cb *axp;
  150. {
  151.     void lapbstate();
  152.  
  153.     lapbstate(axp,DISCONNECTED);
  154.     del_ax25(axp);
  155. }
  156.